// 《围棋》作者版权所有。保留所有权利。
// 此源代码的使用受BSD样式
// 许可证的约束，该许可证可以在许可证文件中找到。

package runtime

import (
	"internal/abi"
	"internal/goarch"
	"runtime/internal/atomic"
	"unsafe"
)

const (
	_SS_DISABLE  = 4
	_SIG_BLOCK   = 1
	_SIG_UNBLOCK = 2
	_SIG_SETMASK = 3
	_NSIG        = 33
	_SI_USER     = 0

	// 来自NetBSD的<sys/ucontext。h> 
	_UC_SIGMASK = 0x01
	_UC_CPU     = 0x04

	// From<sys/lwp。h> go:noescape 
	_LWP_DETACHED = 0x00000040
)

type mOS struct {
	waitsemacount uint32
}

func setitimer(mode int32, new, old *itimerval)

func sigaction(sig uint32, new, old *sigactiont)

func sigaltstack(new, old *stackt)

// go:noescape 
func sigprocmask(how int32, new, old *sigset)

// go:noescape 
func sysctl(mib *uint32, miblen uint32, out *byte, size *uintptr, dst *byte, ndst uintptr) int32

func lwp_tramp()

func raiseproc(sig uint32)

func lwp_kill(tid int32, sig int)

// go:noescape 
func getcontext(ctxt unsafe.Pointer)

// go:noescape 
func lwp_create(ctxt unsafe.Pointer, flags uintptr, lwpid unsafe.Pointer) int32

// go:noescape 
func lwp_park(clockid, flags int32, ts *timespec, unpark int32, hint, unparkhint unsafe.Pointer) int32

// go:noescape 
func lwp_unpark(lwp int32, hint unsafe.Pointer) int32

func lwp_self() int32

func osyield()

// go:nosplit 
func osyield_no_g() {
	osyield()
}

func kqueue() int32

// 。h> 
func kevent(kq int32, ch *keventt, nch int32, ev *keventt, nev int32, ts *timespec) int32

func pipe() (r, w int32, errno int32)
func pipe2(flags int32) (r, w int32, errno int32)
func closeonexec(fd int32)
func setNonblock(fd int32)

const (
	_ESRCH     = 3
	_ETIMEDOUT = 60

	_CLOCK_REALTIME  = 0
	_CLOCK_VIRTUAL   = 1
	_CLOCK_PROF      = 2
	_CLOCK_MONOTONIC = 3

	_TIMER_RELTIME = 0
	_TIMER_ABSTIME = 1
)

var sigset_all = sigset{[4]uint32{^uint32(0), ^uint32(0), ^uint32(0), ^uint32(0)}}

// 来自NetBSD的<sys/sysctl。h> 
const (
	_CTL_KERN   = 1
	_KERN_OSREV = 3

	_CTL_HW        = 6
	_HW_NCPU       = 3
	_HW_PAGESIZE   = 7
	_HW_NCPUONLINE = 16
)

func sysctlInt(mib []uint32) (int32, bool) {
	var out int32
	nout := unsafe.Sizeof(out)
	ret := sysctl(&mib[0], uint32(len(mib)), (*byte)(unsafe.Pointer(&out)), &nout, nil, 0)
	if ret < 0 {
		return 0, false
	}
	return out, true
}

func getncpu() int32 {
	if n, ok := sysctlInt([]uint32{_CTL_HW, _HW_NCPUONLINE}); ok {
		return int32(n)
	}
	if n, ok := sysctlInt([]uint32{_CTL_HW, _HW_NCPU}); ok {
		return int32(n)
	}
	return 1
}

func getPageSize() uintptr {
	mib := [2]uint32{_CTL_HW, _HW_PAGESIZE}
	out := uint32(0)
	nout := unsafe.Sizeof(out)
	ret := sysctl(&mib[0], 2, (*byte)(unsafe.Pointer(&out)), &nout, nil, 0)
	if ret >= 0 {
		return uintptr(out)
	}
	return 0
}

func getOSRev() int {
	if osrev, ok := sysctlInt([]uint32{_CTL_KERN, _KERN_OSREV}); ok {
		return int(osrev)
	}
	return 0
}

// go:nosplit 
func semacreate(mp *m) {
}

// go:nosplit 
func semasleep(ns int64) int32 {
	_g_ := getg()
	var deadline int64
	if ns >= 0 {
		deadline = nanotime() + ns
	}

	for {
		v := atomic.Load(&_g_.m.waitsemacount)
		if v > 0 {
			if atomic.Cas(&_g_.m.waitsemacount, v, v-1) {
				return 0 // 信号量已获取
			}
			continue
		}

		// 在信号唤醒或超时前睡眠。
		var tsp *timespec
		var ts timespec
		if ns >= 0 {
			wait := deadline - nanotime()
			if wait <= 0 {
				return -1
			}
			ts.setNsec(wait)
			tsp = &ts
		}
		ret := lwp_park(_CLOCK_MONOTONIC, _TIMER_RELTIME, tsp, 0, unsafe.Pointer(&_g_.m.waitsemacount), nil)
		if ret == _ETIMEDOUT {
			return -1
		}
	}
}

// go:nosplit 
func semawakeup(mp *m) {
	atomic.Xadd(&mp.waitsemacount, 1)
	// 来自NetBSD的_lwp_unpark（2）手册：
	// “如果目标lwp当前没有等待，它将在下一次调用_lwp_park（）时立即返回
	// 。”
	ret := lwp_unpark(int32(mp.procid), unsafe.Pointer(&mp.waitsemacount))
	if ret != 0 && ret != _ESRCH {
		// 可以在信号堆栈上调用semawakup。
		systemstack(func() {
			print("thrwakeup addr=", &mp.waitsemacount, " sem=", mp.waitsemacount, " ret=", ret, "\n")
		})
	}
}

// 可能在m.p==nil的情况下运行，因此不允许使用写屏障。
// go:nowritebarrier 
func newosproc(mp *m) {
	stk := unsafe.Pointer(mp.g0.stack.hi)
	if false {
		print("newosproc stk=", stk, " m=", mp, " g=", mp.g0, " id=", mp.id, " ostk=", &mp, "\n")
	}

	var uc ucontextt
	getcontext(unsafe.Pointer(&uc))

	// \u UC_SIGMASK在这里似乎不起作用。
	// 如果_UC_SIGMASK和_UC_STACK 
	// 工作正常，我们就可以完成所有设置
	// 这里的SIGMASK和堆栈的工作，而不是设置
	// 这里的掩码和netbsdMstart中的堆栈。
	// 目前，请手动执行阻塞。
	uc.uc_flags = _UC_SIGMASK | _UC_CPU
	uc.uc_link = nil
	uc.uc_sigmask = sigset_all

	var oset sigset
	sigprocmask(_SIG_SETMASK, &sigset_all, &oset)

	lwp_mcontext_init(&uc.uc_mcontext, stk, mp, mp.g0, abi.FuncPCABI0(netbsdMstart))

	ret := lwp_create(unsafe.Pointer(&uc), _LWP_DETACHED, unsafe.Pointer(&mp.procid))
	sigprocmask(_SIG_SETMASK, &oset, nil)
	if ret < 0 {
		print("runtime: failed to create new OS thread (have ", mcount()-1, " already; errno=", -ret, ")\n")
		if ret == -_EAGAIN {
			println("runtime: may need to increase max user processes (ulimit -p)")
		}
		throw("runtime.newosproc")
	}
}

// mstart是新Ms的入口点。
// 它是在汇编中编写的，使用ABI0，标记为TOPFRAME，并调用netbsdMstart0。
func netbsdMstart()

// netbsdMStart0是开始执行新创建的线程的函数调用。在NetBSD上，新线程继承了创建线程的信号堆栈
// 。这让minit感到困惑，所以在调用常规MSStart之前，我们先删除这里的
// 信号堆栈。在这里删除一个信号栈，只在minit中添加一个，这有点像巴洛克风格，但这是一个简单的改变，让NetBSD像其他操作系统一样工作。此时，所有信号都被阻止，所以没有竞争。
// go:nosplit 
func netbsdMstart0() {
	st := stackt{ss_flags: _SS_DISABLE}
	sigaltstack(&st, nil)
	mstart0()
}

func osinit() {
	ncpu = getncpu()
	if physPageSize == 0 {
		physPageSize = getPageSize()
	}
	needSysmonWorkaround = getOSRev() < 902000000 // NetBSD 9.2 
}

var urandom_dev = []byte("/dev/urandom\x00")

// go:nosplit 
func getRandomData(r []byte) {
	fd := open(&urandom_dev[0], 0 /* O_RDONLY */, 0)
	n := read(fd, unsafe.Pointer(&r[0]), int32(len(r)))
	closefd(fd)
	extendRandom(r, int(n))
}

func goenvs() {
	goenvs_unix()
}

// 。
// 在父线程（引导时为主线程）上调用，可以分配内存。
func mpreinit(mp *m) {
	mp.gsignal = malg(32 * 1024)
	mp.gsignal.m = mp
}

// 调用以初始化新的m（包括引导程序m）。
// 在新线程上被调用，无法分配内存。
func minit() {
	_g_ := getg()
	_g_.m.procid = uint64(lwp_self())

	// 在NetBSD上，由pthread_create创建的线程继承创建线程的
	// 信号堆栈。我们总是在这里创建一个
	// 新的信号堆栈，以避免两个Go线程使用同一个信号堆栈。这打破了C中创建的线程
	// 调用sigaltstack，然后调用Go 
	// 函数的情况，因为我们将无法跟踪C代码的
	// sigaltstack，但这是我们所能做的最好的事情。
	signalstack(&_g_.m.gsignal.stack)
	_g_.m.newSigstack = true

	minitSignalMask()
}

// 从dropm调用以撤消minit的效果。
// go:nosplit 
func unminit() {
	unminitSignals()
}

// 从exitm调用，而不是从drop调用，以撤销线程拥有的
// minit、semacreate或其他资源的效果。打完电话后不要带锁。
func mdestroy(mp *m) {
}

func sigtramp()

type sigactiont struct {
	sa_sigaction uintptr
	sa_mask      sigset
	sa_flags     int32
}

// go:nosplit 
// go:nowritebarrierrec 
func setsig(i uint32, fn uintptr) {
	var sa sigactiont
	sa.sa_flags = _SA_SIGINFO | _SA_ONSTACK | _SA_RESTART
	sa.sa_mask = sigset_all
	if fn == abi.FuncPCABIInternal(sighandler) { // abi。FuncPCABIInternal（sighandler）匹配signal_unix中的调用者。go-
		fn = abi.FuncPCABI0(sigtramp)
	}
	sa.sa_sigaction = fn
	sigaction(i, &sa, nil)
}

// go:nosplit-
// go:nowritebarrierrec-
func setsigstack(i uint32) {
	throw("setsigstack")
}

// go:nosplit-
// go:nowritebarrierrec-
func getsig(i uint32) uintptr {
	var sa sigactiont
	sigaction(i, nil, &sa)
	return sa.sa_sigaction
}

// setSignaltstackSP设置堆栈的ss_sp字段。go:nosplit 
func setSignalstackSP(s *stackt, sp uintptr) {
	s.ss_sp = sp
}

// go:nosplit 
func sigaddset(mask *sigset, i int) {
	mask.__bits[(i-1)/32] |= 1 << ((uint32(i) - 1) & 31)
}

func sigdelset(mask *sigset, i int) {
	mask.__bits[(i-1)/32] &^= 1 << ((uint32(i) - 1) & 31)
}

// go:nosplit 
func (c *sigctxt) fixsigcode(sig uint32) {
}

func setProcessCPUProfiler(hz int32) {
	setProcessCPUProfilerTimer(hz)
}

func setThreadCPUProfiler(hz int32) {
	setThreadCPUProfilerHz(hz)
}

// go:nosplit 
func validSIGPROF(mp *m, c *sigctxt) bool {
	return true
}

func sysargs(argc int32, argv **byte) {
	n := argc + 1

	// 跳过argv，envp到达auxv 
	for argv_index(argv, n) != nil {
		n++
	}

	// 跳过空分隔符
	n++

	// 现在argv+n是auxv 
	auxv := (*[1 << 28]uintptr)(add(unsafe.Pointer(argv), uintptr(n)*goarch.PtrSize))
	sysauxv(auxv[:])
}

const (
	_AT_NULL   = 0 // 终止向量
	_AT_PAGESZ = 6 // 以字节为单位的页面大小
)

func sysauxv(auxv []uintptr) {
	for i := 0; auxv[i] != _AT_NULL; i += 2 {
		tag, val := auxv[i], auxv[i+1]
		switch tag {
		case _AT_PAGESZ:
			physPageSize = val
		}
	}
}

// raise向调用线程发送信号。
// 
// 它必须是nosplit，因为它在
// 之前由信号处理程序使用。它肯定有一个Go堆栈。
// 
// go:nosplit 
func raise(sig uint32) {
	lwp_kill(lwp_self(), int(sig))
}

func signalM(mp *m, sig int) {
	lwp_kill(int32(mp.procid), sig)
}

// sigPerThreadSyscall仅在linux上使用，因此我们分配了一个伪信号
// number。
const sigPerThreadSyscall = 1 << 31

// go:nosplit 
func runPerThreadSyscall() {
	throw("runPerThreadSyscall only valid on linux")
}
